package com.parking.bang.rpc.core.thread;

import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ThreadPoolExecutor;

/**
 * Thread Abort policy. sop related message
 * 
 * @author ivan
 *
 */
public class RPCThreadAbortPolicy extends ThreadPoolExecutor.AbortPolicy {

	private final String threadName;

	public RPCThreadAbortPolicy(String threadName) {
		this.threadName = threadName;
	}

	public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
		String rejectMess = String.format(
				"RpcServer["
						+ " Thread Name: %s, Pool Size: %d (active: %d, core: %d, max: %d, largest: %d), Task: %d (completed: %d),"
						+ " Executor status:(isShutdown:%s, isTerminated:%s, isTerminating:%s)]",
				threadName, e.getPoolSize(), e.getActiveCount(), e.getCorePoolSize(), e.getMaximumPoolSize(),
				e.getLargestPoolSize(), e.getTaskCount(), e.getCompletedTaskCount(), e.isShutdown(), e.isTerminated(),
				e.isTerminating());

		System.out.println(rejectMess);

		throw new RejectedExecutionException(rejectMess);
	}

}
